--[[
    编码: JX-115-10
    名称: 空料箱初始化-导入
    作者：HAN    
    日期：2025-1-29    
    入口函数： Import

    功能说明:

    变更历史:

--]]
wms_base = require ("wms_base")
wms_cntr= require( "wms_container" )

function Import(strLuaDEID)
    local nRet, strRetInfo, strNo
    local cntr_spec = {"A","B","C","D","","E"}
    -- 获取导入的数据, 返回 [{"attr":"xx","value":""},...]
    local row_data = {}
    nRet, row_data = m3.GetSysDataJson(strLuaDEID)
    if (nRet ~= 0 or strRetInfo == '') then lua.Error( strLuaDEID, debug.getinfo(1), "无法获取导入数据!") end

    local row_attrs
    local n, nCount, nRows, nIndex
    local cntr_type, max_cell_num

    -- 导入是可分多页分批导入， 因此每次的起始行不一样
    nRet, strRetInfo = mobox.getGlobalAttrValue( strLuaDEID, "start_row" )
    if ( nRet ~= 0 ) then
        mobox.error( strLuaDEID, "获取批量导入全局参数 start_row 失败!"..strRetInfo )
        return
    end    
    local nStartRow = tonumber( strRetInfo )
    local err_msg_list = {}                          -- 用于写导入错误信息
    local str_err_msg
    local empty_box, cntr
    local strCondition, strUpdateSql

    -- 步骤1 获取从excel导入的一行数据
    nRow = nStartRow
    for row = 1, #row_data do
        row_attrs = row_data[row]

        -- 初始化空料箱对象
        empty_box = m3.AllocObject(strLuaDEID,"JX_ASRS_EmptyBox_In")
        str_err_msg = ''
        for n = 1, #row_attrs do
            strAttr = row_attrs[n].attr
            strValue = row_attrs[n].value
            if (strAttr ~= '') then
                if (strAttr == "容器编码") then
                    if (strValue == '') then 
                        str_err_msg = strAttr .. "不能为空!"
                        goto err_msg_process
                    end
                    empty_box.cntr_code = strValue
                elseif (strAttr == "来源系统") then
                    if (strValue == '') then 
                        str_err_msg = strAttr .. "不能为空!"
                        goto err_msg_process
                    end                  
                    empty_box.source_sys = strValue
                elseif (strAttr == "料格数") then
                    empty_box.max_cell_num = lua.StrToNumber( strValue )  
                                
                end
            end
        end
        -- 判断导入的数据是否完整
        if ( empty_box.source_sys == "巨沃" ) then
            if ( empty_box.max_cell_num < 1 or empty_box.max_cell_num > 6 or empty_box.max_cell_num == 5 ) then  
                str_err_msg = "料格数量不合法!"
                goto err_msg_process
            end  
        end        

        if ( str_err_msg == '' ) then
            -- 判断料箱是否存在
            if ( wms_cntr.Exist( strLuaDEID, empty_box.cntr_code ) == false ) then
                -- 没有容器需要创建
                nRet, empty_box = m3.CreateDataObj(strLuaDEID, empty_box)
                if (nRet ~= 0 ) then 
                    str_err_msg = "创建空料箱初始化对象失败!"..empty_box 
                    goto err_msg_process
                end  

                cntr = m3.AllocObject(strLuaDEID,"Container")
                cntr.code = empty_box.cntr_code
                if ( empty_box.source_sys == "巨沃" ) then
                    cntr.type = 3           -- 料箱
                    cntr.spec = cntr_spec[empty_box.max_cell_num]
                    cntr.max_cell_num = empty_box.max_cell_num
                    cntr.source = "巨沃"
                else
                    cntr.type = 2
                    cntr.source = "巨星"
                end
                nRet, cntr = m3.CreateDataObj(strLuaDEID, cntr)
                if (nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "创建料箱对象失败!"..cntr ) end                  
            else
                -- 容器已经存在需要判断容器是否和货位有绑定
                strCondition = "S_CNTR_CODE = '"..empty_box.cntr_code.."'"
                nRet, strRetInfo = mobox.existThisData( strLuaDEID, "CG_Detail", strCondition )
                if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo )  end
                -- 如果该车辆编码的动作已经在队列，返回，不做处理
                if ( strRetInfo ~= "no" ) then 
                    str_err_msg = "料箱'"..empty_box.cntr_code.."'还存在绑定的货品!" 
                    goto err_msg_process                    
                end      
                nRet, strRetInfo = mobox.existThisData( strLuaDEID, "Loc_Container", strCondition )
                if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo )  end
                -- 如果该车辆编码的动作已经在队列，返回，不做处理
                if ( strRetInfo ~= "no" ) then 
                    str_err_msg = "料箱'"..empty_box.cntr_code.."'还存在绑定的货位!" 
                    goto err_msg_process                    
                end 
                
                nRet, empty_box = m3.CreateDataObj(strLuaDEID, empty_box)
                if (nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "创建空料箱初始化对象失败!"..empty_box ) end

                -- 更新容器基本信息
                if ( empty_box.source_sys == "巨沃" ) then
                    cntr_type = 3           -- 料箱
                    cntr_spec = cntr_spec[empty_box.max_cell_num]
                    max_cell_num = empty_box.max_cell_num
                else
                    cntr_type = 2
                    cntr_spec = ""
                    max_cell_num = 0
                end                
                strUpdateSql = "N_TYPE = "..cntr_type..", S_SPEC = '"..cntr_spec.."', N_MAX_CELL_NUM = "..max_cell_num..", "..
                               "N_EMPTY_CELL_NUM = "..max_cell_num..", N_ALLOC_CELL_NUM = 0, S_POSITION = '', S_SOURCE = '"..empty_box.source_sys.."',"..
                               "N_EMPTY_FULL = 0, N_LOCK_STATE = 0, N_B_STATE = 0, C_ENABLE = 'Y', F_GOOD_WEIGHT = 0"
                strCondition = "S_CODE = '"..empty_box.cntr_code.."'"
                nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Container", strCondition, strUpdateSql )
                if ( nRet ~= 0 ) then  lua.Error( strLuaDEID, debug.getinfo(1),  "更新料箱信息失败!"..strRetInfo ) end                   
            end            
        end

        ::err_msg_process::
        if ( str_err_msg ~= '' ) then
            local err_msg_row = {
                row_no = nRow,
                err_msg = str_err_msg
            }
            table.insert( err_msg_list, err_msg_row )            
        end
        nRow = nRow + 1
    end
    -- 把导入过程中的错误信息返回到前端
    local import_fail = {
        result = {
            fail = err_msg_list
        }
    }
    mobox.returnValue( strLuaDEID,1, lua.table2str(import_fail) )
    lua.Debug( strLuaDEID, debug.getinfo(1), "import_fail", import_fail )    
end